package redis.redis;

import redis.clients.jedis.Jedis;

public class ListenThread implements Runnable {

	private Jedis jredis;
	private MyListener myListener;

	public ListenThread(Jedis jredis, MyListener myListener) {
		super();
		this.jredis = jredis;
		this.myListener = myListener;
	}

	public void run() {
		myListener = new MyListener();
		jredis.subscribe(myListener, "topic");

	}

}
